package com.dduggs.note.activemq.queue;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
 * Created by ChenJiasheng on 2017/10/25.
 */
public class AppConsumer {

    private static final String url = "tcp://127.0.0.1:61616";
    private static final String queueName = "queue-test";

    public static void main(String[] args) throws JMSException {

        //1.创建ConnectionFactory
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
        //2.创建Connection
        Connection connection = connectionFactory.createConnection();
        //3.启动连接
        connection.start();
        //4.创建会话
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //5.创建一个目标
        Destination destination = session.createQueue(queueName);
        //6.创建一个消费者
        MessageConsumer consumer=session.createConsumer(destination);
        //7.创建一个监听器(异步)
        consumer.setMessageListener(message -> {
            TextMessage textMessage= (TextMessage) message;
            try {
                System.out.println("接收消息"+textMessage.getText());
            } catch (JMSException e) {
                e.printStackTrace();
            }
        });
        //8.关闭连接
//        connection.close();
    }

}
